package cn.xiaosiyuan.example.filterMessageExample;

import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.exception.MQClientException;

public class Consumer {

    public static void main(String[] args) throws MQClientException {
        // 在大多数情况下，TAG是一个简单而有用的设计，其可以来选择您想要的消息。例如：
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("CID_EXAMPLE");
        consumer.subscribe("TOPIC", "TAGA || TAGB || TAGC");
        /**
         * 消费者将接收包含TAGA或TAGB或TAGC的消息。但是限制是一个消息只能有一个标签，这对于复杂的场景可能不起作用。
         */
    }

}
